package com.mingserve.common.core.constant;

/**
 * Raw原始数据解析 MQTT Kafka 相关常量
 *
 * @author lvwshuai
 * @date 2023-02-16
 */
public class RawConstants
{
    /**
     * 边缘端MQTT
     */
    public static final String MQTT_DAQ = "daq";
    /**
     * 明思为云端MQTT
     */
    public static final String MQTT_MSW = "msw";

    /**
     * HTTP方式
     */
    public static final String HTTP = "HTTP";
    /**
     * MQTT方式
     */
    public static final String MQTT = "MQTT";

    /**
     * MQTT方式
     */
    public static final String MQTT_SCADA = "MQTT_SCADA";

    /* HTTP相关 */
    /**
     * HTTP上传 明文数据
     */
    public static final String HTTP_UPLOAD = "upload";
    /**
     * HTTP上传 adlink数采器数据
     */
    public static final String HTTP_ADLINK_UPLOAD = "adlink/upload";
    /**
     * HTTP上传zlib压缩 Base64数据流-整包
     */
    public static final String HTTP_STREAM_ZIP = "stream/upload";
    /**
     * HTTP上传zlib压缩 Base64数据流-分包
     */
    public static final String HTTP_STREAM_SUB_ZIP = "stream/subpkg/upload";
    /**
     * HTTP上传未压缩 Base64数据流-整包
     */
    public static final String HTTP_RAW_UNZIP = "unzip/upload";
    /**
     * HTTP上传未压缩 Base64数据流-分包
     */
    public static final String HTTP_RAW_SUB_UNZIP = "unzip/subpkg/upload";
    /**
     * HTTP上传原始转速信息
     */
    public static final String HTTP_RAW_RPM = "upload/rpm";

    /* MQTT相关 */
    /**
     * MQTT上传Base64数据流zlib压缩-整包
     */
    public static final String MQTT_RAW_ZIP = "raw/data";
    /**
     * MQTT上传Base64数据流zlib压缩-分包
     */
    public static final String MQTT_RAW_SUB_ZIP = "raw/subpkg";
    /**
     * MQTT上传Base64数据流未压缩-整包
     */
    public static final String MQTT_RAW_UNZIP = "unzip/data";
    /**
     * MQTT上传Base64数据流未压缩-分包
     */
    public static final String MQTT_RAW_SUB_UNZIP = "unzip/subpkg";
    /**
     * MQTT上传统计包信息
     */
    public static final String MQTT_RAW_CONN = "conn/info";

    /**
     * MQTT上传原始转速信息
     */
    public static final String MQTT_RAW_RPM = "raw/rpm";

    /**
     * 大任水务Scada数据
     */
    public static final String MQTT_RAW_DAREN_SCADA = "DAREN_SCADA";

    /**
     * 大任水务Scada数据
     */
    public static final String KAFKA_RAW_DAREN_SCADA_TOPIC = "raw-daren-scada";

    /* Kafka相关 */
    /**
     * 未压缩的数据包、统计包
     */
    public static final String KAFKA_RAW_DATA_TOPIC = "raw-data";
    /**
     * 未压缩的adlink数据包
     */
    public static final String KAFKA_RAW_ADLINK_TOPIC = "raw-adlink";
    /**
     * 压缩的数据包
     */
    public static final String KAFKA_RAW_ZIP_TOPIC = "raw-zip";
    /**
     * 压缩的数据子包
     */
    public static final String KAFKA_RAW_SUB_ZIP_TOPIC = "raw-sub-zip";

    /**
     * 未压缩的数据包
     */
    public static final String KAFKA_RAW_UNZIP_TOPIC = "raw-unzip";
    /**
     * 未压缩的数据子包
     */
    public static final String KAFKA_RAW_SUB_UNZIP_TOPIC = "raw-sub-unzip";

    /**
     * 真实转速数据
     */
    public static final String KAFKA_RAW_PRM_TOPIC = "raw-rpm";

    /**
     * 插值转速数据
     */
    public static final String KAFKA_ANGULAR_PRM_TOPIC = "angular-rpm";

    /**
     * 角域重采数据
     */
    public static final String KAFKA_RAW_ANGULAR_TOPIC = "raw-angular";

    /**
     * Kafka 原始数据解析后转发至算法Kafka Topic
     */
    public static final String KAFKA_TRANS_RAW_TOPIC = "iphm_raw_data";
    /**
     * Kafka 原始数据按工作机组攒包后转发至算法Kafka Topic
     */
    public static final String KAFKA_TRANS_RAW_GROUP_TOPIC = "iphm_raw_group";

    /**
     * 芯片Mac地址
     */
    public static final String CHIP_ID = "ChipID";
    /**
     * 时间戳
     */
    public static final String TIMESTAMP = "Timestamp";
    /**
     * 测点编码
     */
    public static final String POINT_CODE = "PointCode";
    /**
     * x轴数据
     */
    public static final String ACC_X = "accX";
    /**
     * y轴数据
     */
    public static final String ACC_Y = "accY";
    /**
     * z轴数据
     */
    public static final String ACC_Z = "accZ";
    /**
     * 时间间隔
     */
    public static final String ACC_T = "accT";
    /**
     * x轴数据
     */
    public static final String VEL_X = "velX";
    /**
     * y轴数据
     */
    public static final String VEL_Y = "velY";
    /**
     * z轴数据
     */
    public static final String VEL_Z = "velZ";
    /**
     * 固件温度
     */
    public static final String OBJECT_TEMPERATURE = "ObjectTemp";
    /**
     * 采样频率
     */
    public static final String VIB_SAMPLE_FREQUENCY = "VibSampleFreq";
    /**
     * 倍率
     */
    public static final String GAIN = "Gain";
    /**
     * 温度
     */
    public static final String TEMPERATURE = "Temperature";

    /**
     * 事件时间
     */
    public static final String EVENT_TIME = "eventTime";

    /**
     * Wifi信号强度
     */
    public static final String WIFI_RSSI = "wifiRssi";

    /**
     * 电池电压(V)
     */
    public static final String BATTERY_VOLTAGE = "batteryVoltage";
    /**
     * 配置信息
     */
    public static final String CONFIG_INFO = "configInfo";
    /**
     * 版本号
     */
    public static final String VERSION = "version";
}
